9aa541dfe95fc23927e15b7cadd1a3d2f168e8b9,src/java/org/mule/impl/MuleProxy.java,MuleProxy,run,#,465
Before Change
//dispatch the next receiver
RequestContext.setEvent(event);
Object replyTo = event.getMessage().getReplyTo();
ReplyToHandler replyToHandler = ((AbstractConnector) event.getEndpoint().getConnector()).getReplyToHandler();
InterceptorsInvoker invoker = new InterceptorsInvoker(interceptorList, descriptor, event.getMessage());
//do stats
long startTime = 0;
if (stat.isEnabled())
{
startTime = System.currentTimeMillis();
}
UMOMessage result = invoker.execute();
if (stat.isEnabled())
{
stat.addExecutionTime(System.currentTimeMillis() - startTime);
}
// processResponse(result, replyTo, replyToHandler);
event = (MuleEvent) RequestContext.getEvent();
if (result != null && !event.isStopFurtherProcessing())
{
descriptor.getOutboundRouter().route(result, event.getSession(), event.isSynchronous());
}
//process repltyTo if there is one
if (result != null && replyTo != null)
{
String requestor = (String) result.getProperty(MuleProperties.MULE_REPLY_TO_REQUESTOR_PROPERTY);
if (replyToHandler != null)
{
if ((requestor != null && !requestor.equals(descriptor.getName())) ||
requestor == null)
After Change
//dispatch the next receiver
RequestContext.setEvent(event);
Object replyTo = event.getMessage().getReplyTo();
ReplyToHandler replyToHandler = null;
if(replyTo!=null) {
replyToHandler = ((AbstractConnector) event.getEndpoint().getConnector()).getReplyToHandler();
}
InterceptorsInvoker invoker = new InterceptorsInvoker(interceptorList, descriptor, event.getMessage());
//do stats
long startTime = 0;
if (stat.isEnabled())
{
startTime = System.currentTimeMillis();
}
UMOMessage result = invoker.execute();
if (stat.isEnabled())
{
stat.addExecutionTime(System.currentTimeMillis() - startTime);
}
// processResponse(result, replyTo, replyToHandler);
event = (MuleEvent) RequestContext.getEvent();
if (result != null && !event.isStopFurtherProcessing())
{
descriptor.getOutboundRouter().route(result, event.getSession(), event.isSynchronous());
}
//process repltyTo if there is one
if (result != null && replyToHandler != null)
{
String requestor = (String) result.getProperty(MuleProperties.MULE_REPLY_TO_REQUESTOR_PROPERTY);
if ((requestor != null && !requestor.equals(descriptor.getName())) ||